package cn.tedu.charging.order.rabbitmq;

import com.rabbitmq.client.Channel;
import org.junit.jupiter.api.Test;

import java.io.IOException;

/**
 * 创建 声明 我们需要的组件
 */
public class Declare {
    //创建一个queue01队列
    @Test
    public void declareQueue01() throws Exception {
        //1.操作只要和rabbitmq有关 必须拿到channel
        Channel channel = ChannelManager.createChannel();
        //2.声明创建一个队列
        //参数1 String queue: 你提供的队列名称
        channel.queueDeclare("queue01",false,false,false,null);
        //3.关闭channel
        channel.close();
    }
}
